package com.tydic;

import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.io.jdbc.JDBCInputFormat;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.sources.StreamTableSource;

public class JDBCTableSource implements StreamTableSource {

    private final JDBCInputFormat jdbcInputFormat;

    public JDBCTableSource(JDBCInputFormat jdbcInputFormat) {
        this.jdbcInputFormat = jdbcInputFormat;
    }

    @Override
    public DataStream getDataStream(StreamExecutionEnvironment execEnv) {
        return null;
    }

    @Override
    public TypeInformation getReturnType() {
        return null;
    }

    @Override
    public TableSchema getTableSchema() {
        return null;
    }
}
